package com.yuyou.train.stream;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface  SourceSender {
	
	@Input("sourceSender2")
	SubscribableChannel sourceSender3();
	
    @Output(Sink.INPUT) // input通道输出
    MessageChannel output();

    @Output("input2") // input2通道输出
    MessageChannel output2();
	
    @Output("input3") // input3通道输出
    MessageChannel output3();
}
